const got = require('got');
const { kvEvent, EVENT } = require('../lib/event');

const pushUrl = 'https://qyapi.weixin.qq.com/cgi-bin/webhook/send?key=1b9b4b07-b422-40a0-810a-c1664d356118';

kvEvent.on(EVENT.NO_SYNC, ({ key, consulValue, dbValue, user = '相关人员'  }) => {
  consulValue = consulValue || '';
  dbValue = dbValue || '';
  got.post(pushUrl, {
    json: {
      msgtype: 'markdown',
      markdown: {
        content: `\`${ key }\`


> **警报类型：**<font color="warning">值冲突</font>


> **consul：** ${ consulValue.replace(/ /g, '　') || '<font color="warning">未配置</font>' }


> **db：** ${ dbValue.replace(/ /g, '　') || '<font color="warning">未配置</font>' }

请上一个作者 \`${ user }\` 及时前往 [这里](http://work.weixin.qq.com/api/doc) 处理。
`,
        mentioned_list: ['@all'],
      },
    },
  }, (error) => {
    console.log(error);
  });
});

kvEvent.on(EVENT.DIFF_VALUE, ({ key, consulValue, dbValue, user = '相关人员' }) => {
  consulValue = consulValue || '';
  dbValue = dbValue || '';
  got.post(pushUrl, {
    json: {
      msgtype: 'markdown',
      markdown: {
        content: `\`${ key }\`


> **警报类型：** <font color="warning">值冲突</font>


> **consul：** ${ consulValue.replace(/ /g, '　') }


> **db：** ${ dbValue.replace(/ /g, '　') }


请上一个作者 \`${ user }\` 及时前往 [这里](http://work.weixin.qq.com/api/doc) 处理。
`,
      },
    },
  }, (error) => {
    console.log(error);
  });
});